//package com.wudl.report.utils;
//
//import org.apache.kafka.clients.producer.ProducerConfig;
//import org.apache.kafka.common.serialization.StringSerializer;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.kafka.core.DefaultKafkaProducerFactory;
//import org.springframework.kafka.core.KafkaTemplate;
//import org.springframework.kafka.core.ProducerFactory;
//
//import java.util.HashMap;
//import java.util.Map;
//
///**
// * @ClassName : KafkaProducerConfig
// * @Description : kafka 生产者配置类
// * @Author :wudl
// * @Date: 2020-11-02 23:29
// */
//@Configuration
//public class KafkaProducerConfig {
//
//
//    @Value("node01.com:6667")
//    private  String bootstrap_servers_config;
//
//    @Value("${kafka.retries_config}")
//    private int retries_config;
//
//    @Value("${kafka.batch_size_config}")
//    private int batch_size_config;
//
//    @Value("${kafka.linger_ms_config}")
//    private int linger_ms_config;
//
//    @Value("${kafka.buffer_memory_config}")
//    private int buffer_memory_config;
//
//
//
//    public KafkaTemplate getKafkaTemplate()
//    {
//        Map<String,Object> configs = new HashMap<>();
//        configs.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "node01.com:6667");
//        configs.put(ProducerConfig.RETRIES_CONFIG, retries_config);
//        configs.put(ProducerConfig.BATCH_SIZE_CONFIG, batch_size_config);
//        configs.put(ProducerConfig.LINGER_MS_CONFIG, linger_ms_config);
//        configs.put(ProducerConfig.BUFFER_MEMORY_CONFIG, buffer_memory_config);
//
//        // 设置key value的序列化器
//        configs.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
//        configs.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
//
//        // 指定自定义分区
//        configs.put(ProducerConfig.PARTITIONER_CLASS_CONFIG, RoundRobinPartitioner.class);
//        // 创建生产者工厂
//        ProducerFactory<String, String> producerFactory = new DefaultKafkaProducerFactory(configs);
//        // 要返回一个KafkTemplate的对象
//        return new KafkaTemplate(producerFactory);
//    }
//
//}
